package com.lzq.mq.common.dto;

import lombok.Data;
import lombok.EqualsAndHashCode;

/**
 * 消费者拉消息请求
 */
@EqualsAndHashCode(callSuper = true)
@Data
public class ConsumeMsgReqDTO extends BaseBrokerRemoteDTO {

    private String topic;
    private String consumeGroup;
    /**
     * 队列ID
     */
    private Integer queueId;
    private String ip;
    private Integer port;
    private Integer batchSize;
}
